#ifndef THREAD_BASE_H
#define THREAD_BASE_H
#include <queue>
using namespace std;
class Thread_Impl
{
public:
    Thread_Impl();
public:
    virtual ~Thread_Impl(void);
public:
    //开始主动线程运行
    int     activate (int n_threads = 1);

    int     thr_count (void) const;
protected:
    void    wait();//等待线程退出
private:
    virtual  int svc()=0;//主动工作线程函数

    static void * svc_run( void *apParam);//TCP收包处理线程
private:
    std::queue<unsigned long int>		 h_threads;
};

#endif // THREAD_BASE_H
